package cn.monkey.transport.mq.rabbitmq;

import cn.money.transport.mq.MqInbound;
import cn.monkey.transport.mq.rabbitmq.codec.Codec;
import reactor.rabbitmq.ConsumeOptions;

public interface RabbitMqInbound extends MqInbound {

    Codec codec();

    ConsumeOptions consumeOptions();
}
